package com.example.iot.service.websocket;

import com.example.iot.entity.dto.TsData;
import com.example.iot.entity.id.EntityId;
import com.example.iot.ts.TimeSeriesSubscriptionInfo;

/**
 * @author ChenXiangpeng
 */
public interface SubscriptionService {
    void addSubscription(TimeSeriesSubscriptionInfo<String> subscriptionInfo);

    void onTimeSeriesUpdate(EntityId entityId, TsData tsData);

    void cancelAllSubscription(String sessionId);
}
